
input {
  tcp {
    port => {{ INPUT_PORT }}
    type => "tcp_log"
    codec=> json_lines
     }
}
 
output{      
   if [type] == "tcp_log" {
                elasticsearch {
                        hosts => {{ ES_HOSTS|to_json }}
                        index => "tcplog-%{+YYYY.MM.dd}"
                }
        }   
}
